from sqlalchemy.ext.asyncio import AsyncSession
from app.models import Activity


async def collect_xhs(session: AsyncSession, activity_id: str, keywords: list[str] | None = None, accounts: dict | None = None) -> int:
    act = await session.get(Activity, activity_id)
    if not act:
        return 0
    return 0
